package com.kancy.streamplus.channel;
import com.fasterxml.jackson.annotation.JsonIgnore;

import java.io.Serializable;
/**
 * PollingMessage
 *
 * @author kancy
 * @date 2020/3/22 14:55
 */

public interface PollingMessage extends Serializable {
    String INPUT = "pollingInput";
    String OUTPUT = "pollingOutput";
    String EMAIL_KEY = "emailKey";
    String MESSAGE_KEY = "messageKey";
    String CHANNEL_NAME = "channelName";
    String MESSAGE_HANDLER = "messageHandler";
    String MESSAGE_TYPE = "messageType";
    String FIRST_QUERY_TIMESTAMP = "firstQueryTimestamp";
    String LAST_QUERY_TIMESTAMP = "lastQueryTimestamp";
    String DELAY = "delay";
    String MESSAGE_STRATEGY = "messageStrategy";
    String FREQUENCY = "frequency";
    String RETRY_COUNT = "retryCount";
    String MAX_RETRY_TIMES = "maxRetryTimes";
    String MAX_LIVE_TIME = "maxLiveTime";

    /**
     * 消息渠道配置对应的key
     * @return
     */
    @JsonIgnore
    String getMessageKey();
}
